15c2bb3c89e38186c5a59950fdb9c7d9c78fb351,src/java/org/apache/cassandra/tools/SSTableExport.java,SSTableExport,export,#SSTableReader#PrintStream#String[]#,247
Before Change
{
row = (SSTableIdentityIterator) scanner.next();
if (excludeSet.contains(bytesToHex(row.getKey().key)))
continue;
else if (elementWritten)
outs.println(",");
try
{
serializeRow(outs, row);
// used to decide should we put ',' after previous row or not
if (!elementWritten)
elementWritten = true;
}
catch (IOException ioexcep)
{
System.err.println("WARNING: Corrupt row " + bytesToHex(row.getKey().key) + " (skipping).");
elementWritten = false;
}
catch (OutOfMemoryError oom)
{
System.err.println("ERROR: Out of memory deserializing row " + bytesToHex(row.getKey().key));
elementWritten = false;
}
}
After Change
// collecting keys to export
while (scanner.hasNext())
{
row = (SSTableIdentityIterator) scanner.next();
String currentKey = bytesToHex(row.getKey().key);
if (excludeSet.contains(currentKey))
continue;
else if (i != 0)
outs.println(",");
serializeRow(reader, row, row.getKey(), outs);
i++;
}